package com.example.mqtt.server.netty;

/**
 * MQTT的线程类
 */
public class MqttServerThread extends Thread{
    private final int port;

    public MqttServerThread(int port){
        this.port = port;
    }

    @Override
    public void run() {
        // 启动一个MQTT服务端
        MqttServer bootNettyMqttServer = new MqttServer();
        bootNettyMqttServer.startup(this.port);
    }
}
